package Creating_Observables

import (
	"fmt"
	"github.com/reactivex/rxgo/v2"
)

// 将一个数组转化成一个可观察对象，然后发布数据数据
func Demo_Just() {
	observable := rxgo.Just(1, 2, 3)()
	for item := range observable.Observe() {
		if item.Error() {
			fmt.Println("订阅 2：", item.E)
		}
		fmt.Println("订阅 2：", item.V)
	}
}

func Demo_JustItem() {
	observable := rxgo.Just(1)()
	for item := range observable.Observe() {
		if item.Error() {
			fmt.Println("订阅 2：", item.E)
		}
		fmt.Println("订阅 2：", item.V)
	}
}

func Demo_Range() {
	observable := rxgo.Range(0, 3)
	for item := range observable.Observe() {
		if item.Error() {
			fmt.Println("订阅 2：", item.E)
		}
		fmt.Println("订阅 2：", item.V)
	}
}
